package com.hexinfo.dmpro.sparing.service;


import cn.hutool.core.io.file.FileAppender;
import com.hexinfo.dmpro.sparing.dto.DistCPDTO;
import com.hexinfo.dmpro.sparing.dto.TableDistCPDTO;
import com.hexinfo.dmpro.sparing.model.SyncCompleteLibrary;
import com.hexinfo.dmpro.sparing.model.UatSyncLogs;

import java.util.concurrent.Future;

/**
 * DistCP操作类
 * 针对所有java调用sh脚本启动DistCP方式
 *
 */
public interface DataRefreshService {

    Future<Boolean> execShell(TableDistCPDTO tableDistCPDTO, String backupSort, int sizes, FileAppender heatlog, FileAppender tableLog);

    String souTableIsFinishWgToUat(String targetName, UatSyncLogs uatSyncLogs);

    String souTableIsFinishDatabase(String prefix,String targetName);

    void updateEndFlag(String souName,Boolean state);

    Boolean getEndFlag(String souName);

    void deleteEndFlag(String souName);

}
